package cn.itcast.bean;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.math.BigDecimal;

/**
 * 数据清洗bean对象，接收kafka字符串数据
 */
@Data
@AllArgsConstructor
@NoArgsConstructor
public class CleanBean {

    private String mdStreamId;//证券类型
    private String secCode; //证券代码
    private String secName; //证券名称
    private Long tradeVolumn; //日成交总量
    private Long tradeAmt; //日成交总金额
    private BigDecimal preClosePrice; //前收盘价
    private BigDecimal openPrice; //开盘价
    private BigDecimal highPrice; //最高价
    private BigDecimal lowPrice; //最低价
    private BigDecimal tradePrice; //最新价/收盘价
    private Long eventTime; //事件时间  9592211100
    private String source; //数据源
}
